package com.example.reactor;

import reactor.core.publisher.Flux;

public class FluxDemo2 {

    public static void main(String[] args) {

//        Flux.concat(Flux.just(1, 2, 3), Flux.just(4, 5, 6))
//                .subscribe(System.out::println);

        /**
         * 发布者
         * 订阅者
         * 订阅关系
         * 处理器
         */
        Flux.range(1, 8)
                .log()
                .filter(i -> i > 3)
                .log()
                .map(i -> i + "嘿嘿")
                .log()
                .subscribe(System.out::println);

    }

}
